
    <!DOCTYPE html>
    <html lang="zh-CN">
    <head>
      <meta charset="UTF-8">
      <meta name="viewport" content="width=device-width, initial-scale=1.0">
      <title>Kafka的消息如何分配给不同的消费者？ - 学习卡片</title>
      <style>
        body { font-family: sans-serif; background-color: #f0f8ff; color: #333; display: flex; flex-direction: column; align-items: center; padding: 50px 20px; }
        .header h1 { font-size: 32px; }
        .grid-container { display: grid; grid-template-columns: repeat(3, 1fr); gap: 28px; width: 100%; max-width: 1200px; }
        .card-container { perspective: 1200px; cursor: pointer; height: 250px; }
        .card { width: 100%; height: 100%; position: relative; transform-style: preserve-3d; transition: transform 0.7s; border-radius: 16px; box-shadow: 0 4px 16px rgba(0,0,0,0.08); }
        .card-container.flipped .card { transform: rotateY(180deg); }
        .card-face { position: absolute; width: 100%; height: 100%; backface-visibility: hidden; display: flex; flex-direction: column; box-sizing: border-box; border-radius: 16px; background-color: #fff; padding: 24px; }
        .card-back { background-color: #f0fff4; transform: rotateY(180deg); justify-content: space-between; }
        .card-category { font-size: 14px; color: #0052d9; margin-bottom: 8px; font-weight: 500; }
        .card-question { font-size: 20px; font-weight: 500; flex-grow: 1; display: flex; align-items: center; justify-content: center; text-align: center; }
        .card-answer-wrapper { flex-grow: 1; overflow-y: auto; }
        .card-answer { font-size: 15px; line-height: 1.7; }
        .card-footer { font-size: 13px; color: #8a919f; border-top: 1px solid #f0f0f0; padding-top: 16px; margin-top: 16px; }
        .card-source { font-size: 13px; color: #8a919f; border-top: 1px solid #f0f0f0; padding-top: 12px; margin-top: 12px; }
      </style>
    </head>
    <body>
      <div class="header">
        <h1>Kafka的消息如何分配给不同的消费者？ - 学习卡片</h1>
      </div>
      <div class="grid-container">
        
    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">理论</div>
          <div class="card-question">Kafka 是如何利用分区（Partition）来实现高吞吐量和水平扩展的？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">理论</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">Kafka 将一个主题（Topic）分为多个分区，每个分区可以在不同的服务器上并行处理消息。消息在分区内有序，但不同分区之间独立。这种方式允许 Kafka 通过增加分区进行水平扩展，从而提高消息处理的并行性和吞吐量。</div>
          </div>
          <div class="card-source">来源: 文档开篇部分</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">技术</div>
          <div class="card-question">在 Kafka 中，生产者有哪些常见的分区策略来决定消息的分配？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">技术</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">常见的分区策略有三种：1. 默认分区策略：当消息没有键（Key）时，循环选择分区以实现均匀分布。2. 基于键的分区策略：根据消息键的哈希值分配分区，确保相同键的消息进入同一分区。3. 自定义分区策略：通过实现自定义分区器（Partitioner）接口，根据业务逻辑决定分区。</div>
          </div>
          <div class="card-source">来源: 分区策略</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">机制</div>
          <div class="card-question">基于键（Key）的分区策略如何保证相关消息的顺序性？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">机制</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">该策略使用消息键（Key）的哈希值来确定其目标分区。这确保了具有相同键的消息总是被分配到同一个分区中。由于 Kafka 保证单个分区内的消息是有序的，因此相关消息的顺序性就得到了保证。</div>
          </div>
          <div class="card-source">来源: 分区策略</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">理论</div>
          <div class="card-question">什么是 Kafka 消费者组（Consumer Group），它的核心作用是什么？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">理论</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">消费者组是一组具有相同消费者组 ID 的消费者集合。其核心作用是管理消费者，高效地将消息分配给不同的消费者，并保证消息处理的并行性、高可用性和容错性。</div>
          </div>
          <div class="card-source">来源: 消费者组</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">机制</div>
          <div class="card-question">在一个消费者组内，分区是如何分配给消费者的？这一机制解决了什么问题？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">机制</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">在一个消费者组内，Kafka 会将主题的分区动态地分配给组内的消费者，并确保每个分区只能被组内的一个消费者消费。这个机制可以确保每条消息只被消费者组处理一次，从而避免了重复消费和消息丢失的问题。</div>
          </div>
          <div class="card-source">来源: 消费者组</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">特性</div>
          <div class="card-question">什么是消费者重平衡（Consumer Rebalancing），它在什么情况下会发生？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">特性</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">消费者重平衡是指当消费者组内的消费者数量发生变化时（如新的消费者加入或旧的消费者离开），Kafka 会重新将分区分配给消费者组内的所有消费者，以确保负载均衡。这个操作在消费者加入或离开消费者组时被触发。</div>
          </div>
          <div class="card-source">来源: 消费者位移管理</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">理论</div>
          <div class="card-question">什么是消费者位移（Consumer Offset），它在 Kafka 消费过程中扮演什么角色？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">理论</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">消费者位移（Consumer Offset）指示了消费者在每个分区中已经处理的消息的偏移量。消费者会定期提交位移给 Kafka 集群，以便在重启或发生故障后，能够从上次停止的位置继续消费，从而恢复消费进度。</div>
          </div>
          <div class="card-source">来源: 消费者位移管理</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">角色</div>
          <div class="card-question">Kafka 中的消费者组协调器（Group Coordinator）的主要职责是什么？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">角色</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">消费者组协调器的主要职责是管理消费者组的状态和位移提交。它会协调组内的消费者，并将消费者组的位移信息存储在 Kafka 集群的特殊主题中。</div>
          </div>
          <div class="card-source">来源: 消费者位移管理</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">机制</div>
          <div class="card-question">Kafka 是如何实现消费者之间的负载均衡的？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">机制</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">Kafka 通过负载均衡算法来确保消费者组内每个消费者负责处理的分区数量大致相同。当消费者组内成员数量变化时，会触发消费者重平衡（Consumer Rebalancing）操作，重新分配分区，以维持消费者之间的负载均衡状态。</div>
          </div>
          <div class="card-source">来源: 负载均衡</div>
        </div>
      </div>
    </div>

      </div>
    </body>
    </html>
